Global configuration that is passed to Consumer or Producer constructors.
High-level Kafka Consumer, receives messages from a Kafka cluster.
Requires Kafka >= 0.9.0.0.
Kafka Consumer that forwards received messages as events to the application.
Thin abstraction on top of Consumer.
Miscellaneous APIs for the RdKafka library itself.
High-level, asynchronous message producer.
Handle to a topic obtained from Producer.
Internal errors to rdkafka are prefixed with _
The partitioner may be called in any thread at any time, it may be called multiple times for the same message/key.
Partitioner function constraints:
- MUST NOT call any RdKafka methods except forPartitionAvailable(Int32)
- MUST NOT block or execute for prolonged periods of time.
- MUST return a value between 0 and partition_cnt-1, or the special RdKafka.Topic.RD_KAFKA_PARTITION_UA value if partitioning could not be performed.